# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms.dm.dm_center_stop_time_dt import jms_dm__dm_center_stop_time_dt
from jms.dim.dim_network_whole_massage import jms_dim__dim_network_whole_massage



oss__dm_center_stop_time_dt_sum = BashOperator(
    task_id='oss__dm_center_stop_time_dt_sum',
    email=['macheng@jtexpress.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    bash_command='jms/oss/dm_center_stop_time_dt_sum/execute.sh',
    execution_timeout=timedelta(minutes=50),
    sla=timedelta(hours=7)
)

oss__dm_center_stop_time_dt_sum << [ jms_dm__dm_center_stop_time_dt ,jms_dim__dim_network_whole_massage]
